package com.jeffse.light.stream.core.function.base;

import com.jeffse.light.stream.core.pojo.WaterMark;

public interface WaterMarkFunction<T> extends Function {

    WaterMark setWaterMark(T value);

}
